package zhao.exmaple.watearkDemo;

import org.apache.flink.api.common.functions.FilterFunction;

public class WateSensorFilterImpl implements FilterFunction<WateSensor> {
    private String id;
    public WateSensorFilterImpl(String id){
        this.id  = id;
    }
    @Override
    public boolean filter(WateSensor value) throws Exception {
        return value.getId().equals(id);
    }
}
